package com.jd.jobkeeper.transport;

import com.google.protobuf.Message;
import io.rsocket.Payload;
import reactor.core.Disposable;
import reactor.core.publisher.Mono;


public interface Transport extends Disposable {

    void connectWithPayLoad(Payload payload);

    void connect();

    <R> Mono<R> send(String route, Message message, Class<R> type);

    Mono<Void> onClose();
}
